/*
 * 文件名：RealMessageQueueModel.java
 * 版权：亚信联创版权所有
 * 描述：TODO
 * 修改人：napo
 * 修改时间：2014-12-17
 * 修改内容：TODO
 */
package com.ailk.bigdata.etl.realstream.server.protocal.realmq;

import java.io.Serializable;

/**
 * @description TODO
 * @author [xuwei3]
 * @version [版本号,2014-12-17]
 * @see [相关类/方法]
 * @since [产品/模块版本]
 */
public class RealKafkaStreamModel implements Serializable
{
	private static final long serialVersionUID = -4870288969783223544L;
	private String messageTopic;
	private String zkConnect;
	private String consumerGroupId;
	private int numPartitions;
	private int autoCommitEnable;

	public String getMessageTopic()
	{
		return messageTopic;
	}

	public void setMessageTopic(String messageTopic)
	{
		this.messageTopic = messageTopic;
	}

	public String getZkConnect()
	{
		return zkConnect;
	}

	public void setZkConnect(String zkConnect)
	{
		this.zkConnect = zkConnect;
	}

	public String getConsumerGroupId()
	{
		return consumerGroupId;
	}

	public void setConsumerGroupId(String consumerGroupId)
	{
		this.consumerGroupId = consumerGroupId;
	}

	public int getNumPartitions()
	{
		return numPartitions;
	}

	public void setNumPartitions(int numPartitions)
	{
		this.numPartitions = numPartitions;
	}

	public int getAutoCommitEnable()
	{
		return autoCommitEnable;
	}

	public void setAutoCommitEnable(int autoCommitEnable)
	{
		this.autoCommitEnable = autoCommitEnable;
	}

}
